package main

import (
	"fmt"

	"../../../imooc/pipeline"
)

func main() {
	p := pipeline.InMemSOrt(pipeline.ArraySource(3, 2, 6, 7, 4))

	//for {
	//	if num, ok := <-p; ok {
	//		fmt.Println(num)
	//	} else {
	//		break
	//	}
	//
	//}
	for v := range p{
		fmt.Println(v)
	}
}
